package com.yao.mylock.config;

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;

/**
 * @author Macrydy
 * @date 2022/9/19
 */
//@Configuration
public class CuratorConfig {

    //@Bean
    public CuratorFramework curatorFramework() {
        //初始化一个重试策略，这里使用的是指数补偿策略。参数：初始间隔时间 重试次数
        RetryPolicy retry = new ExponentialBackoffRetry(10000, 3);
        //初始化curator客户端
        CuratorFramework client = CuratorFrameworkFactory.newClient("127.0.0.1:2181", retry);
        client.start();//手动启动，否则很多方法或者功能不工作
        return client;
    }
}
